package top.hjcwzx.wrench.mqtt.service.publish;

import com.fasterxml.jackson.core.JsonProcessingException;
import org.eclipse.paho.client.mqttv3.MqttException;

/**
 *
 * <p><b>类名：</b> MqttPublisher</p>
 * <p><b>描述：</b> 消息发布</p>
 * <p><b>创建时间：</b> 2025-06-17 17:01</p>
 *
 * @author 胡锦程
 */
public interface MqttPublisher<T> {
    /**
     * 发送消息
     */
    void publish(String topic, T message) throws MqttException, JsonProcessingException;
}
